package Com.Hfut.Task.Demo;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class RxMsgController {
	private static BlockingQueue<RxMsg> queue =null;// new LinkedBlockingQueue<String>();
	private static RxMsgController _rxmsgController=null;
	
	public static RxMsgController GetInstance(){
        if (_rxmsgController == null)
        {
        	queue=new LinkedBlockingQueue<RxMsg>(); 
        	_rxmsgController = new RxMsgController();
            //obj = new object();
        }
		return _rxmsgController;
	}
	
	public BlockingQueue<RxMsg> GetRxMsgQueue()
	{
		return this.queue;
	}
}
